package com.sgy.rocketMQ;

import com.alibaba.fastjson.JSONObject;
import io.netty.channel.Channel;

import java.util.Map;

public interface OfflineInfoTransmit {

    void pushP2P(Integer uid, JSONObject data);

    void registerPull(Channel channel,Integer uid);

    void unregisterPull(Channel channel);
}
